package com.pancm.datacollector.processor;

import com.pancm.datacollector.queue.CollectedData;

/**
 * 数据处理器接口
 * 所有数据处理器都需要实现此接口
 */
public interface DataProcessor {
    /**
     * 处理数据
     * @param data 待处理的数据
     * @throws Exception 处理过程中的异常
     */
    void process(CollectedData data) throws Exception;


    /**
     * 获取处理器配置
     * @return 处理器配置
     */
    ProcessorConfig getConfig();

    /**
     * 更新处理器配置
     * @param config 新的配置信息
     * @throws Exception 配置更新过程中的异常
     */
    void updateConfig(ProcessorConfig config) throws Exception;
} 